/*
 *  message_receiver.h
 */

#ifndef MESSAGE_RECEIVER_H
#define MESSAGE_RECEIVER_H

#include "message.h"
#include "message_queue.h"
#include "protocol.h"
#include "runnable.h"
#include "socket.h"

// Cross reference class forward declaration
class Session;

class MessageReceiver : public Runnable {
public:
    MessageReceiver(Session* session, MessageQueue& q);
    ~MessageReceiver();
    void run();
private:
    Session* session;
    MessageQueue& q;
};

#endif  //MESSAGE_RECEIVER_H

//{+}

